package com.sanmubird.mywebframework.eventbus.core;

import java.util.List;

public interface MqConsumer<T> extends Runnable {


    MqExchangeEnum getMqRouterEnum();

    List<MqObserver> getMqObserverList();

    String fetchMessage();

    MqMessage<T> convertToMqMessage(String value);
}
